package com.fruit.message;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * @Description:
 * @Author: LJ
 * @Date: 2018/11/2 16:30
 * @version:
 */
public interface StreamClient {
    //该版本Input跟Output value名字一样启动会报错
    String INPUT = "myMessage";

    String INPUT2 = "myMessage2";

//    @Input(StreamClient.INPUT)
//    SubscribableChannel input();

    @Output(StreamClient.INPUT)
    MessageChannel output();

//    @Input(StreamClient.INPUT)
//    SubscribableChannel input2();

    @Output(StreamClient.INPUT2)
    MessageChannel output2();

}
